package 多线程;

/*
    线程的通信
        例题:
            使用两个线程交替打印1到10

        涉及到的方法:
             wait():令当前线程挂起并放弃CPU、同步资源并等待,使别的线程可访问并修改共享资源,而当前线程排队等候其他线程调用notify()或notifyAll()方法唤醒,唤醒后等待重新获得对监视器的所有权后才能继续执行(会释放同步监视器)
             notify():唤醒正在排队等待同步资源的线程中优先级最高者结束等待
             notifyAll():唤醒正在排队等待资源的所有线程结束等待
        注:
             这三个方法只有在synchronized方法或synchronized代码块中才能使用(Lock也不可以),否则会报java.lang.IllegalMonitorStateException异常
             因为这三个方法必须有锁对象调用,而任意对象都可以作为synchronized的同步锁,因此这三个方法只能在Object类中声明
             这三个方法的调用者必须是同步代码块或同步方法中的同步监视器,否则会报异常

        sleep()和wait()的异同
            相同点:
                 一旦执行方法,都可以使得当前线程进入阻塞状态
            不同点
                 两个方法声明的位置不同,Thread类中声明sleep(),Object类中声明wait()
                 调用的要求不同,sleep()可以在任何需要的场景下调用,wait()必须使用在同步代码块或同步方法中
                 是否释放同步监视器:如果两个方法都使用在同步代码块或同步方法中,sleep()不会释放锁,wait()会释放锁
 */
public class ThreadTest13 {

    public static void main(String[] args) {
        Number number = new Number();

        Thread t1 = new Thread(number);
        Thread t2 = new Thread(number);

        t1.setName("线程1");
        t2.setName("线程2");

        t1.start();
        t2.start();
    }
}

class Number implements Runnable{

    private Integer number = 1;
    Object obj = new Object();

    @Override
    public void run() {
            while (true) {
                //synchronized (obj) { 报错
                synchronized (this){
                    this.notify();

                    if (this.number <= 10) {
                        System.out.println(Thread.currentThread().getName() + ":" + this.number++);

                        //调用如下wait()方法的线程进入阻塞状态
                        try {
                            this.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }

                    } else {
                        break;
                    }
                }
        }
    }
}
